<?php
 
 
/*请替换为你自己的数据库名（可从管理中心查看到）*/


$dbname = 'jHhAzjgWCYJBPRsymsLe';
 
/*从环境变量里取host,port,user,pwd*/

if (getenv('HTTP_BAE_ENV_AK')){

	$host = getenv('HTTP_BAE_ENV_ADDR_MONGO_IP');
	$port = getenv('HTTP_BAE_ENV_ADDR_MONGO_PORT');
	$user = getenv('HTTP_BAE_ENV_AK');
	$pwd = getenv('HTTP_BAE_ENV_SK');

} else {

	$host = "127.0.0.1";
	$port = "27017";
	$user = "";
	$pwd = "";

}

function insert($table , $data){
	global $dbname , $host , $port , $user , $pwd ;
	try {
	    /*建立连接后，在进行集合操作前，需要先select使用的数据库，并进行auth*/
	    $mongoClient = new MongoClient("mongodb://{$host}:{$port}");
	    $mongoDB = $mongoClient->selectDB($dbname);
	    if (getenv('HTTP_BAE_ENV_AK'))$mongoDB->authenticate($user, $pwd);
	 
	    /*接下来就可以对该库上的集群进行操作了，具体操作方法请参考php-mongodb官方文档*/
	    $mongoCollection = $mongoDB->selectCollection($table);
	    // $array = array(
	    //     'key1' => 'value1',
	    // );
	    unset($data->id); 
	    $ret = $mongoCollection->insert($data);
	    // $mongoCursor = $mongoCollection->find();
	    // while($mongoCursor->hasNext()) {
	    //     print_r($mongoCursor->getNext());
	    // }
	} catch (Exception $e) {
	    die('error:'.$e->getMessage());
	}
	return  $ret;
}


function find($table){
	global $dbname , $host , $port , $user , $pwd ;
	try {
	    /*建立连接后，在进行集合操作前，需要先select使用的数据库，并进行auth*/
	    $mongoClient = new MongoClient("mongodb://{$host}:{$port}");
	    $mongoDB = $mongoClient->selectDB($dbname);
	    if (getenv('HTTP_BAE_ENV_AK'))$mongoDB->authenticate($user, $pwd);
	 
	    /*接下来就可以对该库上的集群进行操作了，具体操作方法请参考php-mongodb官方文档*/
	    $mongoCollection = $mongoDB->selectCollection($table);
	    // $array = array(
	    //     'key1' => 'value1',
	    // );
	    $ret = array(); //$mongoCollection->find();
	    $mongoCursor = $mongoCollection->find();
	    while($mongoCursor->hasNext()) {
	        array_push($ret ,$mongoCursor->getNext());
	    }
	    
	    return $ret;
	} catch (Exception $e) {
	    die('error:'.$e->getMessage());
	}
	return $ret;
}
?>